package com.youxin.dataStream.state;

/**
 * 与key无关的state,zhengge operator只对应一个state
 * 保存state的数据结构
 *
 *      Flink的kafka Connector,就是用了operator state 他会在每个connector实例中，保存该实例中消费的多有（partition,offset）映射
 *
 * operator eg : BufferingSink.java
 *To use managed operator state, a stateful function can implement either the more general CheckpointedFunction interface, or the ListCheckpointed<T extends Serializable> interface.
 *
 * 详细信息参考官网地址
 * https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/state/state.html
 */
public class OperatorStateText {
}
